google.golang.org/grpc.Server.processStreamingRPC (method)

3 uses

	google.golang.org/grpc (current package)
		server.go#L1578: func (s *Server) processStreamingRPC(ctx context.Context, stream *transport.ServerStream, info *serviceInfo, sd *StreamDesc, trInfo *traceInfo) (err error) {
		server.go#L1846: 			s.processStreamingRPC(ctx, stream, srv, sd, ti)
		server.go#L1852: 		s.processStreamingRPC(ctx, stream, nil, unknownDesc, ti)